import os
from celery import Celery

if not os.environ.get('DJANGO_SETTINGS_MODULE'):
    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings.dev')

celery_app = Celery('demo')
# Celery 相关配置, 比如配置消息队列地址, 也就是中间人的地址
celery_app.config_from_object('celery_tasks.config')

celery_app.autodiscover_tasks(['celery_tasks.sms',
                               'celery_tasks.email',
                               'celery_tasks.html'])
